package com.fang.ct.common.bean;

import java.io.Closeable;

/**
 * 生产者接口
 */
public interface Producer extends Closeable {  //代表可关闭

    /**
     * 数据的输入与输出
     * @param in
     */
    public void setIn(DataIn in);
    public void setOut(DataOut out);

    /**
     * 生产数据
     */
    public void producer();

}
